package com.geek.framework.study.reactive.quickstart;

import reactor.core.publisher.Mono;


public class Client {
  public static void main(String[] args) {
    SimplePublisher<String> publisher = new SimplePublisher<>();
    Mono.from(publisher)
            .subscribe(new SimpleSubscriber(2));
    for (int i = 0 ; i < 10 ; i++)
      publisher.publish("hello, "+ i);

  }

}
